8837527e8f61bc977ffeeac6d25f32714081f6ec,modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffHeapSelfTest.java,GridCacheOffHeapSelfTest,testOffHeap,#,214
Before Change
}
// Query unswapped entries.
Collection<Map.Entry<Integer, CacheValue>> res = cache.queries().
createSqlQuery(CacheValue.class, "val >= ? and val < ?").
execute(0, ENTRY_CNT).
get();
assert res.size() == ENTRY_CNT;
After Change
}
}, EVT_CACHE_OBJECT_TO_OFFHEAP, EVT_CACHE_OBJECT_FROM_OFFHEAP);
IgniteCache<Integer, CacheValue> cache = grid(0).cache(null);
populate(cache);
evictAll(cache);
int cnt = 0;
for (Cache.Entry<Integer, CacheValue> e : cache.localEntries(CachePeekMode.OFFHEAP)) {
assertEquals(e.getKey().intValue(), e.getValue().value());
cnt++;
}
assertEquals(ENTRY_CNT, cnt);
query(cache, 0, 200); // Query swapped entries.
unswap(cache, 200, 400); // Check 'promote' method.
unswapAll(cache, 400, 600); // Check 'promoteAll' method.
get(cache, 600, 800); // Check 'get' method.
peek(cache, 800, ENTRY_CNT); // Check 'peek' method in 'SWAP' mode.
// Check that all entries were unswapped.
for (int i = 0; i < ENTRY_CNT; i++) {
CacheValue val = cache.localPeek(i);
assert val != null;
assert val.value() == i;
}
// Query unswapped entries.
Collection<Cache.Entry<Integer, CacheValue>> res = cache.query(
new SqlQuery<Integer, CacheValue>(CacheValue.class, "val >= ? and val < ?").
setArgs(0, ENTRY_CNT)).
getAll();
assert res.size() == ENTRY_CNT;